package com.ruoyi.toobit.task;

import com.ruoyi.spot.openapi.currencyPair.controller.SpotcurrencyPair;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * 将现货交易对同步（插入/下线入库）加入到可被调度的平台任务中。
 * 运行时由 sys_job 调度，通过 invoke_target 触发：
 *   spotCurrencyPairSyncTask.syncSpotCurrencyPairs()
 */
@Component("spotCurrencyPairSyncTask")
public class SpotCurrencyPairSyncTask {

    private static final Logger logger = LoggerFactory.getLogger("sys-info");

    @Autowired
    private SpotcurrencyPair spotcurrencyPair;

    /**
     * 同步TooBit现货交易对到本地库（新增/下线）。
     */
    public void syncSpotCurrencyPairs() {
        logger.info("⏰ [SpotCurrencyPairSyncTask] 开始执行现货交易对同步...");
        try {
            spotcurrencyPair.compareSpotCurrenyPairs();
            logger.info("✅ [SpotCurrencyPairSyncTask] 同步完成");
        } catch (Exception ex) {
            logger.error("❌ [SpotCurrencyPairSyncTask] 同步失败: {}", ex.getMessage(), ex);
            throw ex;
        }
    }
}


